package com.leigq.www.producer.sender;


import com.leigq.www.common.enums.KafKaMsgBizType;

/**
 * Kafka消息推送者
 *
 * @param <T> the type parameter
 * @author leiguoqing
 */
public interface KafKaSender<T> {


    /**
     * Send.
     *
     * @param msg the msg
     */
    void send(T msg);


    /**
     * Gets biz type.
     *
     * @return the biz type
     */
    KafKaMsgBizType getBizType();

}
